package com.bckj.fastboot.core.extra.txasync;

import java.util.concurrent.ThreadFactory;
import java.util.concurrent.atomic.AtomicInteger;

public class TxAsyncVirtualThreadFactory implements ThreadFactory {

    private final String namePrefix; // 线程名前缀
    private final AtomicInteger threadCounter = new AtomicInteger(1); // 线程计数器

    /**
     * 创建一个虚拟线程工厂。
     *
     * @param namePrefix 线程名前缀
     */
    public TxAsyncVirtualThreadFactory(String namePrefix) {
        this.namePrefix = namePrefix;
    }

    @Override
    public Thread newThread(Runnable task) {
        // 使用 Thread.ofVirtual() 创建虚拟线程
//        return Thread.ofVirtual()
//                .name(namePrefix + "-" + threadCounter.getAndIncrement()) // 设置线程名
//                .unstarted(task); // 绑定任务
        return null;
    }

}